﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace Parallel3M.parallel3m.framework
{
    public class ParallelSinker:ParallelProcessor
    {

        public virtual ParallelPayload getPayload(String payload_id)
        {
            return null;
        }

        public override void process()
        {
            
            foreach (ParallelConnection inputConnection in inputConnections)
            {
                ParallelPayload payload = inputConnection.Flowout();
                if (payload != null)
                {
                    payloadcount++;
                    Console.WriteLine(name + ":" + payload.id);
                }
            }
        }

    }
}
